#include "../../include/db/database.h"
#include "../../include/log/log.h"


// 更新操作

bool MySQL::update(std::string sql)
{
    // RAII机制获取SQL连接
    SqlpoolRAII sqr(_conn, SqlPool::getInstance());
    if (mysql_query(_conn, sql.c_str()))
    {
        LOG_ERROR("更新失败");
        return false;
    }
    return true;
}
// 查询操作
MYSQL_RES *MySQL::query(std::string sql)
{
    // RAII机制获取SQL连接
    SqlpoolRAII sqr(_conn, SqlPool::getInstance());
    if (mysql_query(_conn, sql.c_str()))
    {
        LOG_ERROR("查询失败");
        return nullptr;
    }
    return mysql_use_result(_conn);
}
// 返回MYSQL指针
MYSQLPTR MySQL::getConnection()
{
    return _conn;
}